package com.core.MQ;

import org.springframework.stereotype.Component;

/**
 * 统一消息生产者接口
 * 定义了发送消息的通用行为
 */
public interface MessageProducer {

    /**
     * 发送消息
     *
     * @param topic   主题或路由键。对于RabbitMQ，这可以是routingKey；对于RocketMQ，可以是 "topic:tag"。
     * @param payload 消息体，通常是一个可序列化的对象或Map。
     */
    void sendMessage(String topic, Object payload);
}